google.golang.org/grpc/internal/transport.http2Server.activeStreams (field)

16 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_server.go#L116: 	activeStreams map[uint32]*ServerStream
		http2_server.go#L262: 		activeStreams:     make(map[uint32]*ServerStream),
		http2_server.go#L555: 	if uint32(len(t.activeStreams)) >= t.maxStreams {
		http2_server.go#L617: 	t.activeStreams[streamID] = s
		http2_server.go#L618: 	if len(t.activeStreams) == 1 {
		http2_server.go#L685: 				s := t.activeStreams[se.StreamID]
		http2_server.go#L737: 	if t.activeStreams == nil {
		http2_server.go#L741: 	s, ok := t.activeStreams[f.Header().StreamID]
		http2_server.go#L775: 	for _, s := range t.activeStreams {
		http2_server.go#L941: 	ns := len(t.activeStreams)
		http2_server.go#L1290: 	streams := t.activeStreams
		http2_server.go#L1291: 	t.activeStreams = nil
		http2_server.go#L1308: 	if _, ok := t.activeStreams[s.id]; ok {
		http2_server.go#L1309: 		delete(t.activeStreams, s.id)
		http2_server.go#L1310: 		if len(t.activeStreams) == 0 {
		http2_server.go#L1398: 		if len(t.activeStreams) == 0 {